package main

import (
	"github.com/go-redis/redis"
	"log"
)

var rdb *redis.Client

func Init() {
	// go Subscribe()
}

func main() {
	rdb = redis.NewClient(&redis.Options{
		Addr:     "43.255.53.66:6679", // 使用默认数据库
		Password: "zack@root123.com",  // 没有密码则置空
		DB:       1,                   // 使用默认的数据库
	})

	pong, err := rdb.Ping().Result() // 检查是否连接
	if err != nil {
		log.Fatal(err)
	}

	// 连接成功啦
	log.Println("连接成功：", pong)
	err = rdb.Publish("message", "test").Err()
	if err != nil {
		log.Fatal("发布失败：", err)
		return
	}

}

func Subscribe1() {
	//参数1 频道名 字符串类型
	pubsub := rdb.Subscribe("homework")
	_, err := pubsub.Receive()
	if err != nil {

		return
	}
	ch := pubsub.Channel()
	for msg := range ch {
		log.Fatal("收到订阅消息：", msg.Channel, msg.Payload, "\r\n")
	}

}
